//package com.itclass.oder;
//
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Component;
//
//import java.util.PriorityQueue;
//import java.util.concurrent.*;
//
//@Component
//public class MqService {
//
//
//
//
//    public static volatile ConcurrentMap<Long, OrderCompletableFuture<OrderInfo>> concurrentMap = new ConcurrentHashMap<>();
//    public  static  volatile  PriorityBlockingQueue<Long> priorityQueue = new PriorityBlockingQueue(10000);
//
//    public void sendMessage(Long orderId) throws InterruptedException {
//        MqService.priorityQueue.add(orderId);
//    }
//}
